水利发电机的转速会根据蓄水的高度而发生变化,为了了解发电机的运行状况,需要监测其转速情况(时间窗口内的最大值,最小值和平均值),同时对转速异常值的进行报警。本文以发电机转速监测和异常情况报警的场景为例,详细说明如何使用组件编排进行复杂流数据分析作业的编写以及流数据分析作业如何运作。本文设置的异常值为2000,用户根据实际情况设置相应的值。根据上报数据,区分异常值和正常值两类数据,并分别对异常值进行异常检测和对正常值做聚合计算输出到相应的数据库表中,具体数据处理流程图如下:
创建产品和设备
创建输出表
新建任务
任务编辑
设备输入配置:根据创建的产品,设备和属性选择相应的项,点确定。
数据过滤配置:添加一个转速数值大于正常值(2000)判断的过滤条件,点击确定。
异常检测配置:选择需要检测的字段和异常条件,点确定。
数据源输出配置:根据相应的输入字段,选择输出到对应的数据库表(alarm_data)字段中,点击确定。
注意字段类型和数据库表字段类型必须兼容,否则会出现异常。
说明: 计算维度相当于sql任务的group by后面的字段,计算度量相当于sql任务的统计函数作用的字段,一般是数值类型。
注意字段类型和数据库表字段类型必须兼容,否则会出现异常。
提交任务
模拟设备上传数据和查看运行结果